package org.xq.softcup.mq.remoting.net.impl.netty.client;

import org.xq.softcup.mq.remoting.net.Client;
import org.xq.softcup.mq.remoting.net.common.ConnectClient;
import org.xq.softcup.mq.remoting.net.params.XQRpcRequest;

public class NettyClient extends Client {
    private Class<? extends ConnectClient> connectClientImpl = NettyConnectClient.class;

    public void asyncSend(String address, XQRpcRequest xqRpcRequest)
            throws Exception
    {
        ConnectClient.asyncSend(xqRpcRequest, address, this.connectClientImpl, this.xqRpcReferenceBean);
    }
}
